package com.etlmaster.executor.steps.kafka;

import com.etlmaster.executor.StepMeta;

public class SendStringListToKafkaStepMeta extends StepMeta{

	private String listName;
	private String topic;
	private String partition;
	private String messageType;
	private String message;
	public SendStringListToKafkaStepMeta(String id, String name,String step_code, String session_id, String paramStr) {
		super(id, name,step_code, session_id, paramStr);
	}

	@Override
	protected void loadParamsFromConfigTable() {
		// TODO Auto-generated method stub
		
	}

	public String getListName() {
		return variableSubstitution(listName);
	}

	public void setListName(String listName) {
		this.listName = listName;
	}

	public String getTopic() {
		return variableSubstitution(topic);
	}

	public void setTopic(String topic) {
		this.topic = topic;
	}

	public String getPartition() {
		return variableSubstitution(partition);
	}

	public void setPartition(String partition) {
		this.partition = partition;
	}

	public String getMessageType() {
		return messageType;
	}

	public void setMessageType(String messageType) {
		this.messageType = messageType;
	}

	public String getMessage() {
		return variableSubstitution(message);
	}

	public void setMessage(String message) {
		this.message = message;
	}

}
